package com.juc.blockingQueue.LinkedTransferQueue.tryTransfer;

public class ThreadB1 extends Thread{

	/**
	 * tryTransfer()
	 * 1.如果当前存在一个正在等待获取的消费者线程，使用try-Transfer会立即传输数据
	 * 2.否则，如果不存在，则返回false,并且数据不放入队列中，执行的效果是不阻塞的
	 * 
	 */
	private MyServiceB service;
	
	public ThreadB1 (MyServiceB service) {
		super();
		this.service =service;
	}
	
	@Override
	public void run() {
		System.out.println(Thread.currentThread().getName() + "  beginA  " + System.currentTimeMillis());
	    System.out.println("tryTransfer(e) 返回值为 ： " + service.queue.tryTransfer("我是数据") );
		System.out.println(Thread.currentThread().getName() + "  endA  " + System.currentTimeMillis());

	}
}
